// @File  : rabbitMQ.go
// @Author: JunLong.Liao&此处不应有BUG!
// @Date  : 2021/6/1
// @slogan: 又是不想写代码的一天，神兽保佑，代码无BUG！
//         ┏┓      ┏┓
//        ┏┛┻━━━━━━┛┻┓
//        ┃     ღ    ┃
//        ┃  ┳┛   ┗┳ ┃
//        ┃     ┻    ┃
//        ┗━┓      ┏━┛
//          ┃      ┗━━━┓
//          ┃ 神兽咆哮!  ┣┓
//          ┃         ┏┛
//          ┗┓┓┏━━━┳┓┏┛
//           ┃┫┫   ┃┫┫
//           ┗┻┛   ┗┻┛

package DB

import (
	"courseware/util/config"
	"fmt"
	"github.com/streadway/amqp"
)

var (
	RabbitMQ *amqp.Connection
	AMQPErr  error
)

func ConnectRabbitMQ() error {
	url := fmt.Sprintf("amqp://%s:%s@%s:%s",
		config.Conf.Get("rabbitMQ", "user"),
		config.Conf.Get("rabbitMQ", "password"),
		config.Conf.Get("rabbitMQ", "path"),
		config.Conf.Get("rabbitMQ", "port"))
	RabbitMQ, AMQPErr = amqp.Dial(url)
	if AMQPErr != nil {
		panic(AMQPErr)
		return AMQPErr
	}
	return nil
}
